package com.youshang520i.springcommonmiddleware.service;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.remoting.exception.RemotingException;

import java.io.UnsupportedEncodingException;

/**
 * 广播模式Service
 * @author youshang
 */
public interface BroadcastProducerService {
    /**
     * 发送广播模式MQ
     * @return
     */
    SendResult sendBroadcast() throws UnsupportedEncodingException, InterruptedException, RemotingException, MQClientException, MQBrokerException;

    /**
     * 接收广播模式消息
     */
    void receiveBroadcastResult();
}
